package online.transaction;

import java.util.Objects;

import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.transaction.HeuristicMixedException;
import javax.transaction.HeuristicRollbackException;
import javax.transaction.NotSupportedException;
import javax.transaction.RollbackException;
import javax.transaction.Status;
import javax.transaction.SystemException;
import javax.transaction.UserTransaction;

import org.apache.logging.log4j.LogManager;

import common.transaction.TransactionUtil;

import core.config.Env;
import core.config.Factory;
import core.exception.PhysicalException;

/**
 * ユーザトランザクションユーティリティ
 *
 * @author Tadashi Nakayama
 * @version 1.0.0
 */
public final class XATransactionImpl implements XATransaction {

	/** ローカル変数（ユーザトランザクション用） */
	private static final ThreadLocal<UserTransaction> UT = new ThreadLocal<>();

	/** ロック失敗時のリトライ数 */
	private static final String ENV_ONLINE_RETRY_MAX = "Online.RetryMax";
	/** ロック失敗時のスリープ時間（ミリ） */
	private static final String ENV_ONLINE_RETRY_SLEEP = "Online.RetrySleep";

	/** ユーザトランザクション */
	private static final String ENV_JTA_USER_TRAN = "Jta.UserTransaction";
	/** ユーザトランザクションタイムアウト */
	private static final String ENV_JTA_TIMEOUT = "Jta.TransactionTimeout";

	/** リトライ回数最大値 */
	private static final int RETRY_MAX = Env.getEnv(ENV_ONLINE_RETRY_MAX, 3);
	/** リトライスリープ値 */
	private static final int RETRY_SLEEP = Env.getEnv(ENV_ONLINE_RETRY_SLEEP, 300);

	/** リトライ回数 */
	private int retry = 0;

	/**
	 * トランザクション開始
	 *
	 */
	@Override
	public void beginTransaction() {
		UserTransaction utx = UT.get();
		if (utx == null) {
			String jndi = Env.getEnv(ENV_JTA_USER_TRAN);
			if (!Objects.toString(jndi, "").isEmpty()) {
				utx = lookup(jndi);
			} else {
				UserTransactionProvider utp = Factory.create(UserTransactionProvider.class);
				if (utp == null) {
					return;
				}
				utx = utp.getUserTransaction();
			}
			UT.set(utx);
		}

		try {
			// タイムアウト設定
			int timeout = Env.getEnv(ENV_JTA_TIMEOUT, 0);
			if (0 < timeout) {
				utx.setTransactionTimeout(timeout);
			}

			utx.begin();
			TransactionUtil.begin();
		} catch (SystemException | NotSupportedException ex) {
			LogManager.getLogger().error(ex.getMessage(), ex);
			throw new PhysicalException(ex);
		}
	}

	/**
	 * JNDIルックアップ
	 * @param name JNDI名
	 * @return UserTransaction
	 */
	private UserTransaction lookup(final String name) {
		InitialContext ctx = null;
		try {
			// ユーザトランザクション取得
			ctx = new InitialContext();
			return UserTransaction.class.cast(ctx.lookup(name));
		} catch (NamingException ex) {
			LogManager.getLogger().error(ex.getMessage(), ex);
			throw new PhysicalException(ex);
		} finally {
			if (ctx != null) {
				try {
					ctx.close();
				} catch (NamingException ex) {
					LogManager.getLogger().warn(ex.getMessage(), ex);
				}
			}
		}
	}

	/**
	 * トランザクション終了
	 *
	 */
	@Override
	public void endTransaction() {
		UserTransaction utx = UT.get();
		UT.remove();
		if (utx != null) {
			try {
				if (Status.STATUS_NO_TRANSACTION != utx.getStatus()) {
					utx.rollback();
				}
			} catch (SystemException ex) {
				LogManager.getLogger().error(ex.getMessage(), ex);
			} finally {
				TransactionUtil.end();
			}
		}
	}

	/**
	 * コミット処理
	 *
	 * @return コミット時 true を返す。
	 */
	@Override
	public boolean commit() {
		UserTransaction utx = UT.get();
		if (utx != null) {
			try {
				if (Status.STATUS_ACTIVE == utx.getStatus()) {
					TransactionUtil.end();
					utx.commit();
					return true;
				}
				return false;
			} catch (HeuristicRollbackException | HeuristicMixedException |
					RollbackException | SystemException ex) {
				LogManager.getLogger().error(ex.getMessage(), ex);
				throw new PhysicalException(ex);
			}
		}
		return true;
	}

	/**
	 * ステータス取得
	 *
	 * @return ステータス
	 */
	@Override
	public int getStatus() {
		UserTransaction utx = UT.get();
		if (utx != null) {
			try {
				return utx.getStatus();
			} catch (SystemException ex) {
				LogManager.getLogger().error(ex.getMessage(), ex);
				throw new PhysicalException(ex);
			}
		}
		return Status.STATUS_NO_TRANSACTION;
	}

	/**
	 * リトライ判定
	 *
	 * @return リトライ時 true を返す。
	 */
	@Override
	public boolean mayRetry() {
		this.retry++;
		if (RETRY_MAX <= this.retry) {
			return false;
		}

		endTransaction();
		try {
			Thread.sleep(RETRY_SLEEP);
		} catch (InterruptedException ex) {
			Thread.interrupted();
			LogManager.getLogger().info(ex.getMessage());
			return false;
		}
		beginTransaction();

		return true;
	}
}
